org.springframework.core

Class ReactiveAdapterRegistry.ReactorAdapter

java.lang.Object

org.springframework.core.ReactiveAdapter

org.springframework.core.ReactiveAdapterRegistry.ReactorAdapter

Enclosing class:

ReactiveAdapterRegistry

private static class ReactiveAdapterRegistry.ReactorAdapter
extends ReactiveAdapter

ReactiveAdapter variant that wraps adapted Publishers as Flux or Mono depending on ReactiveTypeDescriptor.isMultiValue(). This is important in places where only the stream and stream element type information is available like encoders and decoders.

Constructor Summary

Constructors

Constructor and Description
ReactorAdapter(ReactiveTypeDescriptor descriptor, java.util.function.Function<java.lang.Object,<any>> toPublisherFunction, java.util.function.Function<<any>,java.lang.Object> fromPublisherFunction)

Method Summary

Modifier and Type	Method and Description
<T> <any>	toPublisher(java.lang.Object source) Adapt the given instance to a Reactive Streams Publisher.

Methods inherited from class org.springframework.core.ReactiveAdapter

fromPublisher, getDescriptor, getReactiveType, isMultiValue, isNoValue, supportsEmpty

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReactorAdapter

ReactorAdapter(ReactiveTypeDescriptor descriptor,
               java.util.function.Function<java.lang.Object,<any>> toPublisherFunction,
               java.util.function.Function<<any>,java.lang.Object> fromPublisherFunction)

Method Detail

toPublisher

public <T> <any> toPublisher(@Nullable
                             java.lang.Object source)

Description copied from class: ReactiveAdapter

Adapt the given instance to a Reactive Streams Publisher.

Overrides:

toPublisher in class ReactiveAdapter

Parameters:

source - the source object to adapt from; if the given object is null, ReactiveTypeDescriptor.getEmptyValue() is used.

Returns:

the Publisher representing the adaptation